package com.yq.canalkafka.service;

import com.alibaba.otter.canal.client.kafka.protocol.KafkaMessage;
import com.alibaba.otter.canal.protocol.CanalEntry;

import java.util.List;

/**
 * @author by shizan
 * @Classname CanalDealService
 * @Description 处理service
 * @Date 2020/11/23 4:28 下午
 */
public interface CanalDealService {
    /**
     * 将消息数据处理落DB
     *
     * @param message
     */
    void printEntries(KafkaMessage message);
}
